package com.eric.demo.ringbuffer;

import com.lmax.disruptor.EventHandler;

/**
 * @author guangyin.zhang
 * @since 2019/3/23
 */
public class LongEventHandler implements EventHandler<LongEvent> {
    @Override
    public void onEvent(LongEvent event, long sequence, boolean endOfBatch) throws Exception {
        System.out.println("Thread:" + Thread.currentThread().getName() + "Event: " + event + ", sequence: " + sequence + ", endOfBatch: " + endOfBatch);
        Thread.sleep(1000);
    }
}
